package org.myorg.datasource.demo.mysql;


import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class MysqlDsFlinkApp {

	public static void main(String[] args) throws Exception {
		final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		env.addSource(new MysqlDatasource()).print();
		env.execute("Flink add mysql datasource");
	}
}
